package com.guaoran.micro.services.spring.cloud.stream.kafka.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @author : gucheng
 * @Description : <br/>
 * @date :2018/12/6 22:53
 */
@Component
public class KafkaConsumerListener {
    @KafkaListener(topics ="${kafka.topic}")
    public void onMessage(String message) {
        System.err.println("Kafka 消费者监听器，接受到消息：" + message);
    }

}
